package com.wujilee.mqdelaytask.service.mq;

import com.wujilee.mqdelaytask.common.MqSupply;

import java.util.function.Consumer;

/**
 * @author liwuji
 * @date 2024/4/12
 * @desc
 **/
public interface MqSender<T> {
    void send(T t);
    default String supportVersion(){
        return MqSupply.KAFKA;
    }
}
    
